package com.xblog.chatbox.vlmp.core.spec;

import com.xblog.chatbox.vlmp.core.VlmpAgentResponse;
import reactor.core.publisher.Flux;

/**
 * @description:
 * @author: xiaowu
 * @time: 2025/8/6 21:28
 */
public class StringStreamResponseSpec implements StreamResponseSpec {

    public static final StringStreamResponseSpec EMPTY_SPEC = new StringStreamResponseSpec(Flux.empty());

    private final Flux<VlmpAgentResponse> content;

    private StringStreamResponseSpec(Flux<VlmpAgentResponse> content) {
        this.content = content;
    }

    public static StringStreamResponseSpec of(Flux<VlmpAgentResponse> content) {
        return new StringStreamResponseSpec(content);
    }
    @Override
    public Flux<VlmpAgentResponse> content() {
        return null;
    }
}
